import pymysql
# 连接数据库
class MyDb():
    def __init__(self):
        self.mydb = pymysql.connect(
            user='root',
            password='Admin@888',
            host='192.168.1.88',
            database='brtc_api',
            port=3306
        )
        # 创建游标
        self.cursor = self.mydb.cursor()
    def get_one(self,sql):
        # 执行sql
        self.cursor.execute(sql)
        # 获取结果
        res = self.cursor.fetchone()
        return res
    def get_many(self,n,sql):
        # 执行sql
        self.cursor.execute(sql)
        # 获取结果
        res = self.cursor.fetchmany(n)
        return res

    # dml语句
    def excute_sql(self,sql):
        # 执行sql
        self.cursor.execute(sql)
        # 提交数据
        self.mydb.commit()
        # 返回结果
        # return self.cursor.rowcount()
    # 析构函数
    def __del__(self):
        self.cursor.close()
        self.mydb.close()
# 实例化对象
mydb = MyDb()

if __name__ == '__main__':
    # print(mydb.get_one("select * from UserName;"))
    print(mydb.get_many(3,"select * from UserName;"))
